package com.yifeng.repo.flink.data.transport.streaming.connectors.tidb.sink;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.flink.streaming.api.functions.sink.SinkFunction;

import com.yifeng.repo.flink.data.transport.config.SinkDbConfig;

/**
 * ClassName: WriteToTidbSinkTest
 * Description: 写入目标数据库sink测试类
 */
public class WriteToTidbSinkTest2 {
	
	public static void main(String[] args) throws Exception {
		
		SinkDbConfig sinkDbConfig = new SinkDbConfig();
		sinkDbConfig.setJdbcUrl("jdbc:mysql://192.168.254.37:59003/yfcloud_transport?allowMultiQueries=true&serverTimezone=Asia/Shanghai");
		sinkDbConfig.setUsername("yfcloud_transport");
		sinkDbConfig.setPassword("Lkoiw_2i354");
		sinkDbConfig.setPoolSize(5);
		Map<String,String> pkMap = new HashMap<String,String>();
		pkMap.put("receiptdetail", "receiptkey,receiptlinenumber");
		sinkDbConfig.setPkMap(pkMap);
		sinkDbConfig.setNeedTransferKeyWord(true);
		sinkDbConfig.setNeedDealKeywordTable("receiptdetail");
		sinkDbConfig.setKeyWord("cube");
		sinkDbConfig.setKeyWordSupplement("_trans");
		Map<String,String> tableMappingMap = new HashMap<String,String>();
		tableMappingMap.put("csds.receiptdetail", "csds_receiptdetail");
		sinkDbConfig.setTableMappingMap(tableMappingMap);
		WriteToTidbSink writeToTidbSink = new WriteToTidbSink(sinkDbConfig);
		
		writeToTidbSink.open(null);
		
		String data = "[\r\n" + 
				"    {\r\n" + 
				"        \"after\": {\r\n" + 
				"            \"REFUSE_FLG\": \"0\",\r\n" + 
				"            \"TOLOC\": \"STAGE\",\r\n" + 
				"            \"DELSTATUS\": null,\r\n" + 
				"            \"RETURNREASON\": null,\r\n" + 
				"            \"SUBLINENUMBER\": \" \",\r\n" + 
				"            \"STORERKEY\": \"1000\",\r\n" + 
				"            \"TOLOT\": null,\r\n" + 
				"            \"PRODUCTIONORDERSCHEDULELINE\": null,\r\n" + 
				"            \"EXTENDEDPRICE\": \"0.00000\",\r\n" + 
				"            \"RECPALOC\": null,\r\n" + 
				"            \"EDITWHO\": \"WMWHSE1\",\r\n" + 
				"            \"REQUISITIONSCHEDULELINE\": null,\r\n" + 
				"            \"ID\": \" \",\r\n" + 
				"            \"READ_FLG\": null,\r\n" + 
				"            \"TYPE\": \"0\",\r\n" + 
				"            \"EXTERNALLOT\": null,\r\n" + 
				"            \"SOURCEVERSION\": null,\r\n" + 
				"            \"STANDARD_UOM_CODE\": null,\r\n" + 
				"            \"SERIALKEY\": \"15595627\",\r\n" + 
				"            \"QTYSEND\": null,\r\n" + 
				"            \"ASSIST2\": null,\r\n" + 
				"            \"UP_CHECK_FLAG\": 0,\r\n" + 
				"            \"CUBICMETER\": \"0.00000\",\r\n" + 
				"            \"HUNDREDWEIGHT\": \"0.00000\",\r\n" + 
				"            \"SEQID\": null,\r\n" + 
				"            \"CUBE\": \"0.00000\",\r\n" + 
				"            \"DISPOSITIONCODE\": null,\r\n" + 
				"            \"RECEIPTKEY\": \"1114535418\",\r\n" + 
				"            \"REASONCODE\": \" \",\r\n" + 
				"            \"REFERENCEVERSION\": null,\r\n" + 
				"            \"PACKKEY\": \"1016736\",\r\n" + 
				"            \"C_LOSEQTY\": null,\r\n" + 
				"            \"IS_PRIMITIVE\": null,\r\n" + 
				"            \"PURCHASEORDERDOCUMENT\": null,\r\n" + 
				"            \"QCREJREASON\": null,\r\n" + 
				"            \"TAREWGT\": \"0.00000\",\r\n" + 
				"            \"REFERENCEACCOUNTINGENTITY\": null,\r\n" + 
				"            \"UPLINENUMBER\": null,\r\n" + 
				"            \"C_JWH\": null,\r\n" + 
				"            \"PURCHASEORDERLOCATION\": null,\r\n" + 
				"            \"FORTE_FLAG\": \"I\",\r\n" + 
				"            \"REFERENCELOCATION\": null,\r\n" + 
				"            \"SALESORDERDOCUMENT\": null,\r\n" + 
				"            \"REFERENCESCHEDULELINE\": null,\r\n" + 
				"            \"SUSR12\": null,\r\n" + 
				"            \"QCQTYREJECTED\": \"0.00000\",\r\n" + 
				"            \"SUSR10\": null,\r\n" + 
				"            \"SUSR11\": null,\r\n" + 
				"            \"GROSSWGT\": \"0.00000\",\r\n" + 
				"            \"QCSTATUS\": \"N\",\r\n" + 
				"            \"C_PIZHWH\": null,\r\n" + 
				"            \"DISPOSITIONTYPE\": null,\r\n" + 
				"            \"REQUISITIONDOCUMENT\": null,\r\n" + 
				"            \"RMA\": null,\r\n" + 
				"            \"PALLETID\": null,\r\n" + 
				"            \"APPROVED_NUMBER\": null,\r\n" + 
				"            \"POKEY\": \" \",\r\n" + 
				"            \"PRODUCTIONORDERLOCATION\": null,\r\n" + 
				"            \"TARIFFKEY\": \"XXXXXXXXXX\",\r\n" + 
				"            \"PURCHASEORDERVERSION\": null,\r\n" + 
				"            \"OTHERUNIT1\": \"0.00000\",\r\n" + 
				"            \"OTHERUNIT2\": \"0.00000\",\r\n" + 
				"            \"EXTERNLINENO\": \" \",\r\n" + 
				"            \"RECEIPTDETAILID\": null,\r\n" + 
				"            \"POLINENUMBER\": null,\r\n" + 
				"            \"PRODUCTIONORDERDOCUMENT\": null,\r\n" + 
				"            \"C_ENTRYUSER\": null,\r\n" + 
				"            \"STATUS\": \"0\",\r\n" + 
				"            \"EDITDATE\": \"2023-06-16 09:53:05\",\r\n" + 
				"            \"SUPPLIERNAME\": null,\r\n" + 
				"            \"ALTSKU\": \" \",\r\n" + 
				"            \"PRODUCTIONORDERVERSION\": null,\r\n" + 
				"            \"PALLET\": \"0.00000\",\r\n" + 
				"            \"PURCHASEORDERSCHEDULELINE\": null,\r\n" + 
				"            \"SALESORDERLINE\": null,\r\n" + 
				"            \"REQUISITIONLINE\": null,\r\n" + 
				"            \"SUSR9\": null,\r\n" + 
				"            \"RETURNCONDITION\": null,\r\n" + 
				"            \"RTW_REASON\": null,\r\n" + 
				"            \"SUSR2\": null,\r\n" + 
				"            \"SUSR1\": null,\r\n" + 
				"            \"SUSR4\": null,\r\n" + 
				"            \"REFERENCELINE\": null,\r\n" + 
				"            \"SALESORDERACCOUNTINGENTITY\": null,\r\n" + 
				"            \"QTYADJUSTED\": \"0.00000\",\r\n" + 
				"            \"SUSR3\": null,\r\n" + 
				"            \"VESSELKEY\": \" \",\r\n" + 
				"            \"IPSKEY\": null,\r\n" + 
				"            \"CONFIRMDATE\": null,\r\n" + 
				"            \"C_ENTRYDATE\": null,\r\n" + 
				"            \"SUSR6\": \"0.00000\",\r\n" + 
				"            \"WHSEID\": \"WMWHSE1\",\r\n" + 
				"            \"SUSR5\": null,\r\n" + 
				"            \"C_PPLP_BOX_ID\": null,\r\n" + 
				"            \"SUSR8\": null,\r\n" + 
				"            \"SUSR7\": null,\r\n" + 
				"            \"DATERECEIVED\": \"2023-06-16 09:53:05\",\r\n" + 
				"            \"IMP_FLG\": \"0\",\r\n" + 
				"            \"ADDWHO\": \"WMWHSE1\",\r\n" + 
				"            \"QTYREJECTED\": \"0.00000\",\r\n" + 
				"            \"VOYAGEKEY\": \" \",\r\n" + 
				"            \"SUMPRICE\": \"13.00000\",\r\n" + 
				"            \"EXTERNRECEIPTKEY\": \"RO2023061600003829\",\r\n" + 
				"            \"QCAUTOADJUST\": \"0\",\r\n" + 
				"            \"QARESULT\": null,\r\n" + 
				"            \"QCQTYINSPECTED\": \"0.00000\",\r\n" + 
				"            \"POQTY\": \"0.0000\",\r\n" + 
				"            \"PURCHASEORDERACCOUNTINGENTITY\": null,\r\n" + 
				"            \"SENDQTY\": null,\r\n" + 
				"            \"MATCHLOTTABLE\": \"0\",\r\n" + 
				"            \"QTYRECEIVED\": \"0.00000\",\r\n" + 
				"            \"UNITPRICE\": \"13.00000\",\r\n" + 
				"            \"RETURNTYPE\": null,\r\n" + 
				"            \"CASECNT\": \"0.00000\",\r\n" + 
				"            \"ASSIST\": null,\r\n" + 
				"            \"QTYEXPECTED\": \"1.00000\",\r\n" + 
				"            \"PURCHASEORDERLINE\": null,\r\n" + 
				"            \"QCUSER\": null,\r\n" + 
				"            \"NOTES\": null,\r\n" + 
				"            \"LOTTABLE01\": \" \",\r\n" + 
				"            \"SUPPLIERKEY\": null,\r\n" + 
				"            \"TEMPERATURE\": null,\r\n" + 
				"            \"LOTTABLE02\": \"0001\",\r\n" + 
				"            \"REQUISITIONLOCATION\": null,\r\n" + 
				"            \"REFERENCETYPE\": null,\r\n" + 
				"            \"SALESORDERVERSION\": null,\r\n" + 
				"            \"SALESORDERSCHEDULELINE\": null,\r\n" + 
				"            \"C_BHAO\": null,\r\n" + 
				"            \"CONFIRMWHO\": null,\r\n" + 
				"            \"REQUISITIONVERSION\": null,\r\n" + 
				"            \"INNERPACK\": \"0.00000\",\r\n" + 
				"            \"RETAIL\": null,\r\n" + 
				"            \"SOURCELOCATION\": null,\r\n" + 
				"            \"XDOCKKEY\": \" \",\r\n" + 
				"            \"PRODUCTIONORDERLINE\": null,\r\n" + 
				"            \"LOTTABLE05\": null,\r\n" + 
				"            \"RTW_RPL\": null,\r\n" + 
				"            \"LOTTABLE06\": \" \",\r\n" + 
				"            \"MAINTENANCE_FLG\": null,\r\n" + 
				"            \"RECEIPTLINENUMBER\": \"00001\",\r\n" + 
				"            \"LOTTABLE03\": \" \",\r\n" + 
				"            \"NETWGT\": \"0.00000\",\r\n" + 
				"            \"LOTTABLE04\": null,\r\n" + 
				"            \"LOTTABLE09\": \" \",\r\n" + 
				"            \"EFFECTIVEDATE\": null,\r\n" + 
				"            \"QCREQUIRED\": \"0\",\r\n" + 
				"            \"LOTTABLE07\": \" \",\r\n" + 
				"            \"LOTTABLE08\": \" \",\r\n" + 
				"            \"C_EXEC_CATE\": null,\r\n" + 
				"            \"TOID\": \" \",\r\n" + 
				"            \"UOM\": \"EA\",\r\n" + 
				"            \"REFERENCEDOCUMENT\": null,\r\n" + 
				"            \"ADDDATE\": \"2023-06-16 09:53:05\",\r\n" + 
				"            \"LOTTABLE12\": null,\r\n" + 
				"            \"C_TC\": null,\r\n" + 
				"            \"LOTTABLE10\": \" \",\r\n" + 
				"            \"LOTTABLE11\": null,\r\n" + 
				"            \"CONTAINERKEY\": \" \",\r\n" + 
				"            \"SKU\": \"1016736\",\r\n" + 
				"            \"CONDITIONCODE\": \"OK\",\r\n" + 
				"            \"PACKINGSLIPQTY\": \"0.00000\",\r\n" + 
				"            \"NOWFLAG\": \"1\",\r\n" + 
				"            \"SALESORDERLOCATION\": null,\r\n" + 
				"            \"REQUISITIONACCOUNTINGENTITY\": null\r\n" + 
				"        },\r\n" + 
				"        \"before\": {\r\n" + 
				"            \"REFUSE_FLG\": \"0\",\r\n" + 
				"            \"TOLOC\": \"STAGE\",\r\n" + 
				"            \"DELSTATUS\": null,\r\n" + 
				"            \"RETURNREASON\": null,\r\n" + 
				"            \"SUBLINENUMBER\": \" \",\r\n" + 
				"            \"STORERKEY\": \"1000\",\r\n" + 
				"            \"TOLOT\": null,\r\n" + 
				"            \"PRODUCTIONORDERSCHEDULELINE\": null,\r\n" + 
				"            \"EXTENDEDPRICE\": \"0.00000\",\r\n" + 
				"            \"RECPALOC\": null,\r\n" + 
				"            \"EDITWHO\": \"WMWHSE1\",\r\n" + 
				"            \"REQUISITIONSCHEDULELINE\": null,\r\n" + 
				"            \"ID\": \" \",\r\n" + 
				"            \"READ_FLG\": null,\r\n" + 
				"            \"TYPE\": \"0\",\r\n" + 
				"            \"EXTERNALLOT\": null,\r\n" + 
				"            \"SOURCEVERSION\": null,\r\n" + 
				"            \"STANDARD_UOM_CODE\": null,\r\n" + 
				"            \"SERIALKEY\": \"15595627\",\r\n" + 
				"            \"QTYSEND\": null,\r\n" + 
				"            \"ASSIST2\": null,\r\n" + 
				"            \"UP_CHECK_FLAG\": 0,\r\n" + 
				"            \"CUBICMETER\": \"0.00000\",\r\n" + 
				"            \"HUNDREDWEIGHT\": \"0.00000\",\r\n" + 
				"            \"SEQID\": null,\r\n" + 
				"            \"CUBE\": \"0.00000\",\r\n" + 
				"            \"DISPOSITIONCODE\": null,\r\n" + 
				"            \"RECEIPTKEY\": \"1114535418\",\r\n" + 
				"            \"REASONCODE\": \" \",\r\n" + 
				"            \"REFERENCEVERSION\": null,\r\n" + 
				"            \"PACKKEY\": \"1016736\",\r\n" + 
				"            \"C_LOSEQTY\": null,\r\n" + 
				"            \"IS_PRIMITIVE\": null,\r\n" + 
				"            \"PURCHASEORDERDOCUMENT\": null,\r\n" + 
				"            \"QCREJREASON\": null,\r\n" + 
				"            \"TAREWGT\": \"0.00000\",\r\n" + 
				"            \"REFERENCEACCOUNTINGENTITY\": null,\r\n" + 
				"            \"UPLINENUMBER\": null,\r\n" + 
				"            \"C_JWH\": null,\r\n" + 
				"            \"PURCHASEORDERLOCATION\": null,\r\n" + 
				"            \"PRODUCTIONORDERACCENTITY\": null,\r\n" + 
				"            \"FORTE_FLAG\": \"I\",\r\n" + 
				"            \"REFERENCELOCATION\": null,\r\n" + 
				"            \"SALESORDERDOCUMENT\": null,\r\n" + 
				"            \"REFERENCESCHEDULELINE\": null,\r\n" + 
				"            \"SUSR12\": null,\r\n" + 
				"            \"QCQTYREJECTED\": \"0.00000\",\r\n" + 
				"            \"SUSR10\": null,\r\n" + 
				"            \"SUSR11\": null,\r\n" + 
				"            \"GROSSWGT\": \"0.00000\",\r\n" + 
				"            \"QCSTATUS\": \"N\",\r\n" + 
				"            \"C_PIZHWH\": null,\r\n" + 
				"            \"DISPOSITIONTYPE\": null,\r\n" + 
				"            \"REQUISITIONDOCUMENT\": null,\r\n" + 
				"            \"RMA\": null,\r\n" + 
				"            \"PALLETID\": null,\r\n" + 
				"            \"APPROVED_NUMBER\": null,\r\n" + 
				"            \"POKEY\": \" \",\r\n" + 
				"            \"PRODUCTIONORDERLOCATION\": null,\r\n" + 
				"            \"TARIFFKEY\": \"XXXXXXXXXX\",\r\n" + 
				"            \"PURCHASEORDERVERSION\": null,\r\n" + 
				"            \"OTHERUNIT1\": \"0.00000\",\r\n" + 
				"            \"OTHERUNIT2\": \"0.00000\",\r\n" + 
				"            \"EXTERNLINENO\": \" \",\r\n" + 
				"            \"RECEIPTDETAILID\": null,\r\n" + 
				"            \"POLINENUMBER\": null,\r\n" + 
				"            \"PRODUCTIONORDERDOCUMENT\": null,\r\n" + 
				"            \"C_ENTRYUSER\": null,\r\n" + 
				"            \"STATUS\": \"0\",\r\n" + 
				"            \"EDITDATE\": \"2023-06-16 09:53:05\",\r\n" + 
				"            \"SUPPLIERNAME\": null,\r\n" + 
				"            \"ALTSKU\": \" \",\r\n" + 
				"            \"PRODUCTIONORDERVERSION\": null,\r\n" + 
				"            \"PALLET\": \"0.00000\",\r\n" + 
				"            \"PURCHASEORDERSCHEDULELINE\": null,\r\n" + 
				"            \"SALESORDERLINE\": null,\r\n" + 
				"            \"REQUISITIONLINE\": null,\r\n" + 
				"            \"SUSR9\": null,\r\n" + 
				"            \"RETURNCONDITION\": null,\r\n" + 
				"            \"RTW_REASON\": null,\r\n" + 
				"            \"SUSR2\": null,\r\n" + 
				"            \"SUSR1\": null,\r\n" + 
				"            \"SUSR4\": null,\r\n" + 
				"            \"REFERENCELINE\": null,\r\n" + 
				"            \"SALESORDERACCOUNTINGENTITY\": null,\r\n" + 
				"            \"QTYADJUSTED\": \"0.00000\",\r\n" + 
				"            \"SUSR3\": null,\r\n" + 
				"            \"VESSELKEY\": \" \",\r\n" + 
				"            \"IPSKEY\": null,\r\n" + 
				"            \"CONFIRMDATE\": null,\r\n" + 
				"            \"C_ENTRYDATE\": null,\r\n" + 
				"            \"SUSR6\": \"0.00000\",\r\n" + 
				"            \"WHSEID\": \"WMWHSE1\",\r\n" + 
				"            \"SUSR5\": null,\r\n" + 
				"            \"C_PPLP_BOX_ID\": null,\r\n" + 
				"            \"SUSR8\": null,\r\n" + 
				"            \"SUSR7\": null,\r\n" + 
				"            \"DATERECEIVED\": \"2023-06-16 09:53:05\",\r\n" + 
				"            \"IMP_FLG\": \"0\",\r\n" + 
				"            \"ADDWHO\": \"WMWHSE1\",\r\n" + 
				"            \"QTYREJECTED\": \"0.00000\",\r\n" + 
				"            \"VOYAGEKEY\": \" \",\r\n" + 
				"            \"SUMPRICE\": \"13.00000\",\r\n" + 
				"            \"EXTERNRECEIPTKEY\": \"RO2023061600003829\",\r\n" + 
				"            \"QCAUTOADJUST\": \"0\",\r\n" + 
				"            \"QARESULT\": null,\r\n" + 
				"            \"QCQTYINSPECTED\": \"0.00000\",\r\n" + 
				"            \"POQTY\": \"0.0000\",\r\n" + 
				"            \"PURCHASEORDERACCOUNTINGENTITY\": null,\r\n" + 
				"            \"SENDQTY\": null,\r\n" + 
				"            \"MATCHLOTTABLE\": \"0\",\r\n" + 
				"            \"QTYRECEIVED\": \"0.00000\",\r\n" + 
				"            \"UNITPRICE\": \"13.00000\",\r\n" + 
				"            \"RETURNTYPE\": null,\r\n" + 
				"            \"CASECNT\": \"0.00000\",\r\n" + 
				"            \"ZLZK\": null,\r\n" + 
				"            \"ASSIST\": null,\r\n" + 
				"            \"QTYEXPECTED\": \"1.00000\",\r\n" + 
				"            \"PURCHASEORDERLINE\": null,\r\n" + 
				"            \"QCUSER\": null,\r\n" + 
				"            \"NOTES\": null,\r\n" + 
				"            \"LOTTABLE01\": \" \",\r\n" + 
				"            \"SUPPLIERKEY\": null,\r\n" + 
				"            \"TEMPERATURE\": null,\r\n" + 
				"            \"LOTTABLE02\": \"0001\",\r\n" + 
				"            \"REQUISITIONLOCATION\": null,\r\n" + 
				"            \"REFERENCETYPE\": null,\r\n" + 
				"            \"SALESORDERVERSION\": null,\r\n" + 
				"            \"SALESORDERSCHEDULELINE\": null,\r\n" + 
				"            \"C_BHAO\": null,\r\n" + 
				"            \"CONFIRMWHO\": null,\r\n" + 
				"            \"REQUISITIONVERSION\": null,\r\n" + 
				"            \"INNERPACK\": \"0.00000\",\r\n" + 
				"            \"RETAIL\": null,\r\n" + 
				"            \"SOURCELOCATION\": null,\r\n" + 
				"            \"XDOCKKEY\": \" \",\r\n" + 
				"            \"PRODUCTIONORDERLINE\": null,\r\n" + 
				"            \"LOTTABLE05\": null,\r\n" + 
				"            \"RTW_RPL\": null,\r\n" + 
				"            \"LOTTABLE06\": \" \",\r\n" + 
				"            \"MAINTENANCE_FLG\": null,\r\n" + 
				"            \"RECEIPTLINENUMBER\": \"00001\",\r\n" + 
				"            \"LOTTABLE03\": \" \",\r\n" + 
				"            \"NETWGT\": \"0.00000\",\r\n" + 
				"            \"LOTTABLE04\": null,\r\n" + 
				"            \"LOTTABLE09\": \" \",\r\n" + 
				"            \"EFFECTIVEDATE\": null,\r\n" + 
				"            \"QCREQUIRED\": \"0\",\r\n" + 
				"            \"LOTTABLE07\": \" \",\r\n" + 
				"            \"QTYCHANGED\": \"N\",\r\n" + 
				"            \"LOTTABLE08\": \" \",\r\n" + 
				"            \"C_EXEC_CATE\": null,\r\n" + 
				"            \"TOID\": \" \",\r\n" + 
				"            \"UOM\": \"EA\",\r\n" + 
				"            \"REFERENCEDOCUMENT\": null,\r\n" + 
				"            \"ADDDATE\": \"2023-06-16 09:53:05\",\r\n" + 
				"            \"LOTTABLE12\": null,\r\n" + 
				"            \"C_TC\": null,\r\n" + 
				"            \"YSJL\": null,\r\n" + 
				"            \"LOTTABLE10\": \" \",\r\n" + 
				"            \"LOTTABLE11\": null,\r\n" + 
				"            \"CONTAINERKEY\": \" \",\r\n" + 
				"            \"SKU\": \"1016736\",\r\n" + 
				"            \"CONDITIONCODE\": \"OK\",\r\n" + 
				"            \"PACKINGSLIPQTY\": \"0.00000\",\r\n" + 
				"            \"NOWFLAG\": \"0\",\r\n" + 
				"            \"SALESORDERLOCATION\": null,\r\n" + 
				"            \"REQUISITIONACCOUNTINGENTITY\": null\r\n" + 
				"        },\r\n" + 
				"        \"database\": \"SCPRD\",\r\n" + 
				"        \"op\": \"c\",\r\n" + 
				"        \"schema\": \"CSDS\",\r\n" + 
				"        \"tb\": \"RECEIPTDETAIL\",\r\n" + 
				"        \"ts_ms\": 1687078236898\r\n" + 
				"    }\r\n" + 
				"]";
		
		writeToTidbSink.invoke(data,new SinkFunction.Context() {
            @Override
            public long currentProcessingTime() {
                throw new RuntimeException("Not implemented");
            }

            @Override
            public long currentWatermark() {
                throw new RuntimeException("Not implemented");
            }

            @Override
            public Long timestamp() {
                return null;
            }
        });
    }
}
